package com.atguigu.sql.data.common

import com.atguigu.sql.util.MySparkSessionUtil
import org.apache.spark.sql.{DataFrame, SparkSession}

/**
 * description ：通用的读取
 * author      ：剧情再美终是戏 
 * mail        : 13286520398@163.com
 * date        ：Created in 2020/1/12 6:49
 * modified By ：
 * version:    : 1.0
 */
object RCommon {

  def main(args: Array[String]): Unit = {

    // 获取 sparkSession
    val spark: SparkSession = MySparkSessionUtil.get(args)

    // TODO 读取文件 通过修改format("xxx")方法来读取不同的文件 如：text, json, parquet, csv, orc...
    // TODO read.format("xxx").load --> read.xxx.load
    val df: DataFrame = spark.read.format("json").load("c:/user-json.txt")

    // 输出
    df.show

    // 关闭 sparkSession 资源
    MySparkSessionUtil.close(spark)
  }

}
